package cn.z2huo.demo.hello.kafka.api;

import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.producer.KafkaProducer;

import java.util.Properties;

/**
 * <p>
 *
 * @author z2huo
 */
public interface KafkaConnectionFactory {

    KafkaProducer<String, String> getProducer(String name);

    KafkaConsumer<String, String> getConsumer(String name);

    KafkaProducer<String, String> getProducer(String name, Properties overrideProps);

    KafkaConsumer<String, String> getConsumer(String name, Properties overrideProps);

}
